package cn.xuqiudong.mq.bridge.mapper;

import cn.xuqiudong.common.base.mapper.BaseGenericMapper;
import cn.xuqiudong.mq.bridge.model.DataBridgeReceiveMessage;
import cn.xuqiudong.mq.bridge.model.FetchMessageLookup;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * 功能: :接收自mq的消息表 Mapper
 *
 * @author Vic.xu
 * @since 2025-03-03 14:55
 */
public interface DataBridgeReceiveMessageMapper extends BaseGenericMapper<DataBridgeReceiveMessage, Integer> {

    List<DataBridgeReceiveMessage> fetchMessageToConsumer(FetchMessageLookup lookup);
}
